package com.nl.pulsardemo.pool.service;

import com.nl.pulsardemo.pool.vo.ResultVO;
import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.PulsarClientException;

/**
 * @author : ZhaoY
 * @description :
 * @date : 2021-02-01 16:14
 **/
public interface IConsumer {

    ResultVO SyncReceive(Consumer consumer) throws PulsarClientException;

    ResultVO AsyncReceive(Consumer consumer);
}
